package cn.iocoder.yudao.module.forward.mqtt;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttMessage;

public interface IMqttCallBack {
    void connectionLost(MqttInfo mqttInfo, Throwable throwable);

    void messageArrived(MqttInfo mqttInfo, String s, MqttMessage mqttMessage) throws Exception;

    void deliveryComplete(MqttInfo mqttInfo, IMqttDeliveryToken iMqttDeliveryToken);

    void connectComplete(MqttInfo mqttInfo, boolean reconnect, String s);

    void onSubscribe(MqttInfo mMqttInfo, boolean ret, String topic);

    void onUnsubscribe(MqttInfo mMqttInfo, boolean ret, String topic);
}
